import { AppSystemProp, QueueMode, system } from '@openops/server-shared';
import { memoryQueue } from '../memory/memory-queue';
import { redisQueue } from '../redis/redis-queue';

const systemMode = system.getOrThrow(AppSystemProp.QUEUE_MODE);
export const flowQueue =
  systemMode == QueueMode.MEMORY ? memoryQueue : redisQueue;
